--[[ 编码: WMS-71-20 名称: 库存量表差异-库存量表差异检测 作者：HAN 日期：2025-1-29 级别：固定 (说明本段代码在项目中不太会变化) 函数： InventoryDiffCheck 功能: 后台处理脚本根据输入的仓库+库区重新计算 仓库、库区里的货品数量信息 1 -- 统计数据 （根据CG_Detai等表计算出来的数据） 2 -- 量表数据 3 -- 内存数据 更改记录: --]] wms_base = require ("wms_base") local function create_inventor_diff( strLuaDEID, check_obj_type, wh_code, area_code, zone_code ) local nRet, strRetInfo, code if ( check_obj_type == nil or check_obj_type == '' ) then return 1, "create_inventor_diff 函数中参数 check_obj_type 必须有值!" end if ( check_obj_type == "Warehouse" ) then if ( wh_code == nil or wh_code == '' ) then return 1, "create_inventor_diff 函数中参数 wh_code 必须有值!" end code = wh_code area_code = '' zone_code = '' elseif ( check_obj_type == "Area" ) then if ( wh_code == nil or wh_code == '' ) then return 1, "create_inventor_diff 函数中参数 wh_code 必须有值!" end if ( area_code == nil or area_code == '' ) then return 1, "create_inventor_diff 函数中参数 area_code 必须有值!" end code = area_code zone_code = '' elseif ( check_obj_type == "Zone" ) then if ( wh_code == nil or wh_code == '' ) then return 1, "create_inventor_diff 函数中参数 wh_code 必须有值!" end if ( area_code == nil or area_code == '' ) then return 1, "create_inventor_diff 函数中参数 area_code 必须有值!" end if ( zone_code == nil or zone_code == '' ) then return 1, "create_inventor_diff 函数中参数 zone_code 必须有值!" end code = zone_code else return 1, "create_inventor_diff 函数中参数 check_obj_type 值非法! "..check_obj_type end -- 根据CG_Detail 统计出库存量 nRet, strRetInfo = wms.wms_StatInventory( strLuaDEID, check_obj_type, code, 200) -- 返回 data_list: [ { "end_user": "", "item_code": "", "item_state": X, "item_route": "", "qty": X ，"qty_alloc":y" },...] if ( nRet ~= 0 ) then return 1, "wms_StatInventory: "..strRetInfo end if ( strRetInfo == '' ) then return 0 end local success, queryInfo, i success, queryInfo = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_StatInventory 返回结果啊非法的JSON格式!" end nPageCount = queryInfo.page_count nPage = 1 data_list = queryInfo.data_list -- 统计出来的数据集 local ret_info, parameter, diff, item_name local item_code, item_state, item_route, end_user, str_cls_id, str_condition local qty, alloc_qty, m_qty, m_alloc_qty, t_qty, t_alloc_qty while (nPage <= nPageCount) do for i = 1, #data_list do item_code = data_list[i].item_code item_state = data_list[i].item_state item_route = data_list[i].item_route end_user = data_list[i].end_user qty = data_list[i].qty alloc_qty = data_list[i].qty_alloc -- 获取内存中的量 m_qty = 0 m_alloc_qty = 0 parameter = {} parameter.end_user = end_user parameter.item_list = {} item = {} item.item_code = item_code item.item_state = item_state item.item_route = item_route parameter.item_list[1] = item str_condition = " S_ITEM_CODE = '"..item_code.."'" if ( check_obj_type == "Warehouse" ) then parameter.wh_code = wh_code nRet, strRetInfo = wms.wms_GetWHInventory( lua.table2str(parameter) ) if (nRet == 0) then ret_info = json.decode( strRetInfo ) m_qty = ret_info[1].qty_storage if ( qty ~= m_qty ) then diff = 'Y' end m_alloc_qty = ret_info[1].qty_alloc else return 1, "wms_GetWHInventory 失败!"..strRetInfo end str_cls_id = "WH_Inventory" str_condition = "S_WH_CODE = '"..wh_code.."' AND "..str_condition elseif (check_obj_type == "Area") then parameter.area_code = area_code nRet, strRetInfo = wms.wms_GetAreaInventory( lua.table2str(parameter) ) if (nRet == 0) then ret_info = json.decode( strRetInfo ) m_qty = ret_info[1].qty_storage m_alloc_qty = ret_info[1].qty_alloc else return 1, "wms_GetAreaInventory 失败!"..strRetInfo end str_cls_id = "AZ_Inventory" str_condition = "S_WH_CODE = '"..wh_code.."' AND S_AREA_CODE = '"..area_code.."' AND C_IS_LOGIC_AREA = 'N' AND "..str_condition else str_cls_id = "AZ_Inventory" str_condition = "S_WH_CODE = '"..wh_code.."' AND S_AREA_CODE = '"..area_code.."' AND C_IS_LOGIC_AREA = 'Y' AND "..str_condition end diff = 'N' if ( qty ~= m_qty ) then diff = 'Y' end if ( alloc_qty ~= m_alloc_qty ) then diff = 'Y' end -- 获取数据库里的量 local inventory err_msg = '' nRet, inventory = m3.GetDataObjByCondition(strLuaDEID, str_cls_id, str_condition ) if (nRet ~= 0) then if ( nRet == 1 ) then err_msg = str_cls_id.."量表中不存在该物料的存储表记录! 严重错误! 查询条件 = "..str_condition else lua.Error( strLuaDEID, debug.getinfo(1), "获取量表记录信息失败! " .. inventory) end item_name = "???" t_qty = 0 t_alloc_qty = 0 else item_name = inventory.item_name t_qty = inventory.qty t_alloc_qty = inventory.alloc_qty end if ( diff == 'N' ) then if ( qty ~= t_qty ) then diff = 'Y' end end if ( diff == 'N' ) then if ( alloc_qty ~= t_alloc_qty ) then diff = 'Y' end end local inventory_diff = m3.AllocObject(strLuaDEID,"WMS_Inventory_Diff") inventory_diff.wh_code = wh_code inventory_diff.area_code = area_code inventory_diff.zone_code = zone_code inventory_diff.item_code = item_code --inventory_diff.item_state = item_state --inventory_diff.item_route = item_route --inventory_diff.end_user = end_user inventory_diff.item_name = item_name inventory_diff.err_msg = err_msg inventory_diff.diff = diff inventory_diff.qty = qty inventory_diff.alloc_qty = alloc_qty inventory_diff.table_qty = t_qty inventory_diff.m_qty = m_qty inventory_diff.m_alloc_qty = m_alloc_qty inventory_diff.table_alloc_qty = t_alloc_qty nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, inventory_diff ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【WMS_Inventory_Diff】对象失败!'..strRetInfo ) end end nPage = nPage + 1 if ( nPage <= nPageCount ) then -- 取下一页 nRet, strRetInfo = wms.wms_StatInventory( strLuaDEID, nPage) if ( nRet ~= 0 ) then return 1, "wms_StatInventory失败! nPage="..nPage.." "..strRetInfo end queryInfo = json.decode(strRetInfo) data_list = queryInfo.data_list end end return 0 end function InventoryDiffCheck ( strLuaDEID ) local nRet, strRetInfo local paramter nRet, paramter = m3.GetSysDataJson( strLuaDEID ) if ( nRet ~=0 ) then lua.Error( strLuaDEID, debug.getinfo(1), paramter ) end -- {"wh_code":"x","area_code":"x"} local wh_code = paramter.wh_code local area_code = paramter.area_code if ( wh_code == nil or wh_code == '') then lua.Error( strLuaDEID, debug.getinfo(1), "仓库编码必须有值! " ) end if ( area_code == nil ) then area_code = '' end if ( area_code ~= '' ) then nRet, strRetInfo = create_inventor_diff( strLuaDEID, "Area", wh_code, area_code ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end else nRet, strRetInfo = create_inventor_diff( strLuaDEID, "Warehouse", wh_code ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end end end